//package study.mq.kafka._1_consumer.support.assignor;
//
//import lombok.extern.slf4j.Slf4j;
//import org.apache.kafka.clients._1_consumer.ConsumerPartitionAssignor;
//import org.apache.kafka.common.Cluster;
//import org.apache.kafka.common.TopicPartition;
//
//import java.util.List;
//
//@Slf4j
//public class CustomPartitionAssignor implements ConsumerPartitionAssignor {
//
//    @Override
//    public GroupAssignment assign(Cluster metadata, GroupSubscription groupSubscription) {
//        groupSubscription.groupSubscription().forEach((k, v) -> {
//            v.groupInstanceId();
//            List<TopicPartition> partitionLt = v.ownedPartitions();
//        });
//        return new GroupAssignment(assignments);
//    }
//
//    @Override
//    public String name() {
//        return "custom";
//    }
//}
